const fs = require('fs')
const path = require('path')

const rs = fs.createReadStream(path.join(__dirname, './a.txt')) // 创建一个可读流
const ws = fs.createWriteStream(path.join(__dirname, './c.txt')) // 创建一个可写流

// 监听流的关闭
rs.once('open', () => {
  console.log('可读流打开了');
})

rs.once('close', () => {
  console.log('可读流关闭了');
})

ws.once('open', () => {
  console.log('可写流打开了');
})

ws.once('close', () => {
  console.log('可写流关闭了');
  ws.end()
})

// // 给可读流添加data事件之后，就会开始读取数据，读取成功一次就会调用一次回调，将读取到的数据以参数的形式返回
rs.on('data', (data) => {
  // console.log(data.length);
  ws.write(data)
})

// rs.on('readable', () => {
//   console.log(rs.read());
// })